Apache Flink এ ক্লাস্টার সেটআপ এবং সিঙ্গল-নোড কনফিগারেশন সেটআপ করার জন্য আপনাকে কিছু স্টেপ অনুসরণ করতে হবে। নিচে বিস্তারিত ভাবে এই স্টেপগুলি ব্যাখ্যা করা হলো:
Apache Flink রান করার জন্য আপনার সিস্টেমে JDK (Java Development Kit) ইনস্টল করা থাকতে হবে। সাধারণত Flink JDK 8 বা তার উপরের ভার্সন সাপোর্ট করে।
চেক করুন:
java -version
Apache Flink এর অফিসিয়াল ওয়েবসাইট থেকে Flink ডাউনলোড করুন: Flink Download
ডাউনলোড করার পর, আর্কাইভটি আনজিপ করুন:
tar -xzf flink-*.tgz
cd flink-*
সিঙ্গল-নোড সেটআপ সাধারণত ডেভেলপমেন্ট বা টেস্টিং পারপাসে ব্যবহৃত হয়। এতে সব কাজ (Job Manager ও Task Manager) একই মেশিনে চলে।
a. Flink Configuration File (flink-conf.yaml) কনফিগার করা:
Flink এর কনফিগারেশন ফাইল conf/flink-conf.yaml
এ আছে। এটি খুলে নিম্নলিখিত পরিবর্তন করুন:
jobmanager.rpc.address: আপনার মেশিনের হোস্টনেম বা IP এড্রেস দিন (সাধারণত localhost বা 127.0.0.1)।
jobmanager.rpc.address: localhost
taskmanager.numberOfTaskSlots: আপনার সিস্টেমের রিসোর্স অনুযায়ী Task Slots সংখ্যা দিন (যেমন 2 বা 4)।
taskmanager.numberOfTaskSlots: 2
Flink এর ক্লাস্টার স্টার্ট করতে নিচের কমান্ডটি চালান:
bin/start-cluster.sh
ক্লাস্টার সফলভাবে স্টার্ট হলে, আপনি Flink এর ওয়েব UI অ্যাক্সেস করতে পারেন: http://localhost:8081। এখানে আপনি ক্লাস্টারের স্ট্যাটাস, রানিং জব, এবং অন্যান্য ডিটেইলস দেখতে পাবেন।
ক্লাস্টারে জব সাবমিট করতে নিচের কমান্ড ব্যবহার করুন:
bin/flink run -c <MainClass> <YourFlinkJar.jar>
এখানে <MainClass>
আপনার অ্যাপ্লিকেশনের প্রধান ক্লাস এবং <YourFlinkJar.jar>
হচ্ছে আপনার তৈরি করা Flink অ্যাপ্লিকেশনের JAR ফাইল।
ক্লাস্টার স্টপ করতে নিচের কমান্ডটি ব্যবহার করুন:
bin/stop-cluster.sh
যদি আপনি মাল্টি-নোড ক্লাস্টার সেটআপ করতে চান, তাহলে আপনাকে একাধিক মেশিনে Flink ইনস্টল করতে হবে এবং সঠিকভাবে flink-conf.yaml
কনফিগার করতে হবে।
এই স্টেপগুলি অনুসরণ করে আপনি Apache Flink এ সিঙ্গল-নোড অথবা মাল্টি-নোড ক্লাস্টার সেটআপ করতে পারবেন। Flink ক্লাস্টার ব্যবস্থাপনা খুবই স্কেলেবল এবং সহজ, যা আপনাকে বাস্তব সময়ে ডাটা স্ট্রিম প্রসেসিং করতে সাহায্য করবে।
আরও দেখুন...